package com.bfl.mq.service;

import com.alibaba.rocketmq.common.message.MessageExt;

public interface IConsumer {
    /**
     * 消费端解析消息
     * @param msg
     */
    void handlerMessage( MessageExt msg );
}
